package com.ydl.learning.flink.demo.pipeline.impl

import com.ydl.learning.flink.demo.mySink.LogSink
import com.ydl.learning.flink.demo.pipeline.{BaseProcedureImpl, PipelineData, Sink}

/**
 *
 *
 * @author ydl
 * @since 2022/1/7
 */
class Sink2Impl extends Sink[PipelineData] with BaseProcedureImpl {

  override def sink(): Unit = {
    source.addSink(new LogSink[PipelineData]).name("log")
  }

}
